package com.xiaozhen.jt809.service;

import com.xiaozhen.jt809.domain.JT809MessageInfo;
import io.netty.channel.ChannelHandlerContext;

/**
 * HISTORY
 *
 * @author zhenweisheng
 * @date 2021/9/16 14:19
 * @description:
 */
public interface MsgHandleService {

    /**
     * 处理接收到的消息
     *
     * @param origin 消息来源
     * @param ctx
     * @param msg    消息
     */
    void handleMessage(String origin, ChannelHandlerContext ctx, Object msg);

    /**
     * 获取要下发的消息
     *
     * @param ctx
     * @param message 要做什么的消息（用来记录到日志）
     * @return
     */
    JT809MessageInfo getMessageInfo(ChannelHandlerContext ctx,String message);
}
